<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">

<html lang="en">

<head>
  <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
  <title>LCOV - coverage_clean.info - home/liying/sqlcc/src/sql_executor/sql_executor.cpp</title>
  <link rel="stylesheet" type="text/css" href="../../../../../gcov.css">
</head>

<body>

          <table width="100%" border=0 cellspacing=0 cellpadding=0>
            <tr><td class="title">LCOV - code coverage report</td></tr>
            <tr><td class="ruler"><img src="../../../../../glass.png" width=3 height=3 alt=""></td></tr>

            <tr>
              <td width="100%">
                <table cellpadding=1 border=0 width="100%">
          <tr>
            <td width="10%" class="headerItem">Current view:</td>
            <td width="10%" class="headerValue"><a href="../../../../../index.html">top level</a> - <a href="index.html">/home/liying/sqlcc/src/sql_executor</a> - sql_executor.cpp<span style="font-size: 80%;"> (source / <a href="sql_executor.cpp.func-c.html">functions</a>)</span></td>
            <td width="5%"></td>
            <td width="5%"></td>
            <td width="5%" class="headerCovTableHead">Coverage</td>
            <td width="5%" class="headerCovTableHead" title="Covered + Uncovered code">Total</td>
            <td width="5%" class="headerCovTableHead" title="Exercised code only">Hit</td>
          </tr>
          <tr>
            <td class="headerItem">Test:</td>
            <td class="headerValue">coverage_clean.info</td>
            <td></td>
            <td class="headerItem">Lines:</td>
            <td class="headerCovTableEntryLo">47.5&nbsp;%</td>
            <td class="headerCovTableEntry">202</td>
            <td class="headerCovTableEntry">96</td>
          </tr>
          <tr>
            <td class="headerItem">Test Date:</td>
            <td class="headerValue">2025-11-25 04:45:29</td>
            <td></td>
            <td class="headerItem">Functions:</td>
            <td class="headerCovTableEntryMed">75.0&nbsp;%</td>
            <td class="headerCovTableEntry">8</td>
            <td class="headerCovTableEntry">6</td>
          </tr>
                  <tr><td><img src="../../../../../glass.png" width=3 height=3 alt=""></td></tr>
                </table>
              </td>
            </tr>

            <tr><td class="ruler"><img src="../../../../../glass.png" width=3 height=3 alt=""></td></tr>
          </table>

          <table cellpadding=0 cellspacing=0 border=0>
            <tr>
              <td><br></td>
            </tr>
            <tr>
              <td>
<pre class="sourceHeading">            Line data    Source code</pre>
<pre class="source">
<span id="L1"><span class="lineNum">       1</span>              : #include &quot;../include/sql_executor.h&quot;</span>
<span id="L2"><span class="lineNum">       2</span>              : #include &quot;../include/user_manager.h&quot;</span>
<span id="L3"><span class="lineNum">       3</span>              : #include &lt;iomanip&gt;</span>
<span id="L4"><span class="lineNum">       4</span>              : #include &lt;iostream&gt;</span>
<span id="L5"><span class="lineNum">       5</span>              : #include &lt;sstream&gt;</span>
<span id="L6"><span class="lineNum">       6</span>              : #include &lt;string&gt;</span>
<span id="L7"><span class="lineNum">       7</span>              : #include &lt;vector&gt;</span>
<span id="L8"><span class="lineNum">       8</span>              : #include &lt;fstream&gt;</span>
<span id="L9"><span class="lineNum">       9</span>              : </span>
<span id="L10"><span class="lineNum">      10</span>              : namespace sqlcc {</span>
<span id="L11"><span class="lineNum">      11</span>              : </span>
<span id="L12"><span class="lineNum">      12</span>              : // 辅助函数：修剪字符串</span>
<span id="L13"><span class="lineNum">      13</span> <span class="tlaGNC tlaBgGNC">          56 : void TrimString(std::string &amp;str) {</span></span>
<span id="L14"><span class="lineNum">      14</span>              :   // 移除开头空白</span>
<span id="L15"><span class="lineNum">      15</span> <span class="tlaGNC">          56 :   size_t start = str.find_first_not_of(&quot; \t\n\r&quot;);</span></span>
<span id="L16"><span class="lineNum">      16</span> <span class="tlaGNC">          56 :   if (start != std::string::npos) {</span></span>
<span id="L17"><span class="lineNum">      17</span> <span class="tlaGNC">          56 :     str = str.substr(start);</span></span>
<span id="L18"><span class="lineNum">      18</span>              :   } else {</span>
<span id="L19"><span class="lineNum">      19</span> <span class="tlaUNC tlaBgUNC">           0 :     str.clear();</span></span>
<span id="L20"><span class="lineNum">      20</span> <span class="tlaUNC">           0 :     return;</span></span>
<span id="L21"><span class="lineNum">      21</span>              :   }</span>
<span id="L22"><span class="lineNum">      22</span>              :   // 移除结尾空白</span>
<span id="L23"><span class="lineNum">      23</span> <span class="tlaGNC tlaBgGNC">          56 :   size_t end = str.find_last_not_of(&quot; \t\n\r&quot;);</span></span>
<span id="L24"><span class="lineNum">      24</span> <span class="tlaGNC">          56 :   if (end != std::string::npos) {</span></span>
<span id="L25"><span class="lineNum">      25</span> <span class="tlaGNC">          56 :     str = str.substr(0, end + 1);</span></span>
<span id="L26"><span class="lineNum">      26</span>              :   } else {</span>
<span id="L27"><span class="lineNum">      27</span> <span class="tlaUNC tlaBgUNC">           0 :     str.clear();</span></span>
<span id="L28"><span class="lineNum">      28</span>              :   }</span>
<span id="L29"><span class="lineNum">      29</span>              : }</span>
<span id="L30"><span class="lineNum">      30</span>              : </span>
<span id="L31"><span class="lineNum">      31</span>              : // SqlExecutor类实现</span>
<span id="L32"><span class="lineNum">      32</span>              : // 与头文件匹配的构造函数实现</span>
<span id="L33"><span class="lineNum">      33</span> <span class="tlaGNC tlaBgGNC">           2 : SqlExecutor::SqlExecutor() {</span></span>
<span id="L34"><span class="lineNum">      34</span>              :   // 初始化user_manager_</span>
<span id="L35"><span class="lineNum">      35</span> <span class="tlaGNC">           2 :   user_manager_ = std::make_shared&lt;UserManager&gt;();</span></span>
<span id="L36"><span class="lineNum">      36</span> <span class="tlaGNC">           2 : }</span></span>
<span id="L37"><span class="lineNum">      37</span>              : </span>
<span id="L38"><span class="lineNum">      38</span> <span class="tlaGNC">           2 : SqlExecutor::~SqlExecutor() {</span></span>
<span id="L39"><span class="lineNum">      39</span>              :   // 析构函数实现</span>
<span id="L40"><span class="lineNum">      40</span> <span class="tlaGNC">           2 : }</span></span>
<span id="L41"><span class="lineNum">      41</span>              : </span>
<span id="L42"><span class="lineNum">      42</span> <span class="tlaGNC">          32 : std::string sqlcc::SqlExecutor::Execute(const std::string &amp;sql) {</span></span>
<span id="L43"><span class="lineNum">      43</span>              :   // 简单的SQL解析和执行逻辑</span>
<span id="L44"><span class="lineNum">      44</span> <span class="tlaGNC">          32 :   std::string trimmed_sql = sql;</span></span>
<span id="L45"><span class="lineNum">      45</span> <span class="tlaGNC">          32 :   TrimString(trimmed_sql);</span></span>
<span id="L46"><span class="lineNum">      46</span>              : </span>
<span id="L47"><span class="lineNum">      47</span> <span class="tlaGNC">          32 :   if (trimmed_sql.empty()) {</span></span>
<span id="L48"><span class="lineNum">      48</span> <span class="tlaUNC tlaBgUNC">           0 :     return &quot;&quot;;</span></span>
<span id="L49"><span class="lineNum">      49</span>              :   }</span>
<span id="L50"><span class="lineNum">      50</span>              : </span>
<span id="L51"><span class="lineNum">      51</span>              :   // 简单的SQL命令判断</span>
<span id="L52"><span class="lineNum">      52</span> <span class="tlaGNC tlaBgGNC">          32 :   if (trimmed_sql.substr(0, 6) == &quot;SELECT&quot;) {</span></span>
<span id="L53"><span class="lineNum">      53</span> <span class="tlaGNC">           2 :     return ExecuteSelect(trimmed_sql);</span></span>
<span id="L54"><span class="lineNum">      54</span> <span class="tlaGNC">          30 :   } else if (trimmed_sql.substr(0, 6) == &quot;INSERT&quot;) {</span></span>
<span id="L55"><span class="lineNum">      55</span> <span class="tlaUNC tlaBgUNC">           0 :     return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L56"><span class="lineNum">      56</span> <span class="tlaGNC tlaBgGNC">          30 :   } else if (trimmed_sql.substr(0, 6) == &quot;UPDATE&quot;) {</span></span>
<span id="L57"><span class="lineNum">      57</span> <span class="tlaUNC tlaBgUNC">           0 :     return &quot;Query OK, 0 rows affected\n&quot;;</span></span>
<span id="L58"><span class="lineNum">      58</span> <span class="tlaGNC tlaBgGNC">          30 :   } else if (trimmed_sql.substr(0, 6) == &quot;DELETE&quot;) {</span></span>
<span id="L59"><span class="lineNum">      59</span> <span class="tlaUNC tlaBgUNC">           0 :     return &quot;Query OK, 0 rows affected\n&quot;;</span></span>
<span id="L60"><span class="lineNum">      60</span> <span class="tlaGNC tlaBgGNC">          30 :   } else if (trimmed_sql.substr(0, 12) == &quot;CREATE USER&quot;) {</span></span>
<span id="L61"><span class="lineNum">      61</span>              :     // 创建用户命令实现</span>
<span id="L62"><span class="lineNum">      62</span> <span class="tlaUNC tlaBgUNC">           0 :     std::string username;</span></span>
<span id="L63"><span class="lineNum">      63</span> <span class="tlaUNC">           0 :     std::string password;</span></span>
<span id="L64"><span class="lineNum">      64</span> <span class="tlaUNC">           0 :     std::string role = &quot;USER&quot;;</span></span>
<span id="L65"><span class="lineNum">      65</span>              : </span>
<span id="L66"><span class="lineNum">      66</span> <span class="tlaUNC">           0 :     size_t user_pos = trimmed_sql.find(&quot;USER&quot;) + 5;</span></span>
<span id="L67"><span class="lineNum">      67</span> <span class="tlaUNC">           0 :     size_t identified_pos = trimmed_sql.find(&quot;IDENTIFIED BY&quot;);</span></span>
<span id="L68"><span class="lineNum">      68</span>              : </span>
<span id="L69"><span class="lineNum">      69</span> <span class="tlaUNC">           0 :     if (identified_pos != std::string::npos) {</span></span>
<span id="L70"><span class="lineNum">      70</span> <span class="tlaUNC">           0 :       username = trimmed_sql.substr(user_pos, identified_pos - user_pos);</span></span>
<span id="L71"><span class="lineNum">      71</span> <span class="tlaUNC">           0 :       TrimString(username);</span></span>
<span id="L72"><span class="lineNum">      72</span>              : </span>
<span id="L73"><span class="lineNum">      73</span> <span class="tlaUNC">           0 :       size_t password_start = identified_pos + 13;</span></span>
<span id="L74"><span class="lineNum">      74</span> <span class="tlaUNC">           0 :       size_t password_end = trimmed_sql.find(';', password_start);</span></span>
<span id="L75"><span class="lineNum">      75</span> <span class="tlaUNC">           0 :       if (password_end == std::string::npos)</span></span>
<span id="L76"><span class="lineNum">      76</span> <span class="tlaUNC">           0 :         password_end = trimmed_sql.length();</span></span>
<span id="L77"><span class="lineNum">      77</span>              : </span>
<span id="L78"><span class="lineNum">      78</span> <span class="tlaUNC">           0 :       password = trimmed_sql.substr(password_start, password_end - password_start);</span></span>
<span id="L79"><span class="lineNum">      79</span> <span class="tlaUNC">           0 :       if (password.front() == '&quot;' &amp;&amp; password.back() == '&quot;') {</span></span>
<span id="L80"><span class="lineNum">      80</span> <span class="tlaUNC">           0 :         password = password.substr(1, password.size() - 2);</span></span>
<span id="L81"><span class="lineNum">      81</span> <span class="tlaUNC">           0 :       } else if (password.front() == '\'' &amp;&amp; password.back() == '\'') {</span></span>
<span id="L82"><span class="lineNum">      82</span> <span class="tlaUNC">           0 :         password = password.substr(1, password.size() - 2);</span></span>
<span id="L83"><span class="lineNum">      83</span>              :       }</span>
<span id="L84"><span class="lineNum">      84</span> <span class="tlaUNC">           0 :       TrimString(password);</span></span>
<span id="L85"><span class="lineNum">      85</span>              :     }</span>
<span id="L86"><span class="lineNum">      86</span>              : </span>
<span id="L87"><span class="lineNum">      87</span> <span class="tlaUNC">           0 :     size_t role_pos = trimmed_sql.find(&quot;ROLE&quot;);</span></span>
<span id="L88"><span class="lineNum">      88</span> <span class="tlaUNC">           0 :     if (role_pos != std::string::npos) {</span></span>
<span id="L89"><span class="lineNum">      89</span> <span class="tlaUNC">           0 :       size_t role_start = role_pos + 5;</span></span>
<span id="L90"><span class="lineNum">      90</span> <span class="tlaUNC">           0 :       size_t role_end = trimmed_sql.find(';', role_start);</span></span>
<span id="L91"><span class="lineNum">      91</span> <span class="tlaUNC">           0 :       if (role_end == std::string::npos)</span></span>
<span id="L92"><span class="lineNum">      92</span> <span class="tlaUNC">           0 :         role_end = trimmed_sql.length();</span></span>
<span id="L93"><span class="lineNum">      93</span> <span class="tlaUNC">           0 :       role = trimmed_sql.substr(role_start, role_end - role_start);</span></span>
<span id="L94"><span class="lineNum">      94</span> <span class="tlaUNC">           0 :       TrimString(role);</span></span>
<span id="L95"><span class="lineNum">      95</span>              :     }</span>
<span id="L96"><span class="lineNum">      96</span>              : </span>
<span id="L97"><span class="lineNum">      97</span> <span class="tlaUNC">           0 :     if (user_manager_-&gt;CreateUser(username, password, role)) {</span></span>
<span id="L98"><span class="lineNum">      98</span> <span class="tlaUNC">           0 :       return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L99"><span class="lineNum">      99</span>              :     } else {</span>
<span id="L100"><span class="lineNum">     100</span> <span class="tlaUNC">           0 :       SetError(user_manager_-&gt;GetLastError());</span></span>
<span id="L101"><span class="lineNum">     101</span> <span class="tlaUNC">           0 :       return &quot;ERROR: &quot; + user_manager_-&gt;GetLastError();</span></span>
<span id="L102"><span class="lineNum">     102</span>              :     }</span>
<span id="L103"><span class="lineNum">     103</span> <span class="tlaGNC tlaBgGNC">          30 :   } else if (trimmed_sql.substr(0, 10) == &quot;DROP USER&quot;) {</span></span>
<span id="L104"><span class="lineNum">     104</span>              :     // 删除用户命令实现</span>
<span id="L105"><span class="lineNum">     105</span> <span class="tlaUNC tlaBgUNC">           0 :     std::string username;</span></span>
<span id="L106"><span class="lineNum">     106</span> <span class="tlaUNC">           0 :     bool if_exists = false;</span></span>
<span id="L107"><span class="lineNum">     107</span>              : </span>
<span id="L108"><span class="lineNum">     108</span> <span class="tlaUNC">           0 :     if (trimmed_sql.find(&quot;IF EXISTS&quot;) != std::string::npos) {</span></span>
<span id="L109"><span class="lineNum">     109</span> <span class="tlaUNC">           0 :       if_exists = true;</span></span>
<span id="L110"><span class="lineNum">     110</span> <span class="tlaUNC">           0 :       size_t user_pos = trimmed_sql.find(&quot;IF EXISTS&quot;) + 9;</span></span>
<span id="L111"><span class="lineNum">     111</span> <span class="tlaUNC">           0 :       size_t user_end = trimmed_sql.find(';', user_pos);</span></span>
<span id="L112"><span class="lineNum">     112</span> <span class="tlaUNC">           0 :       if (user_end == std::string::npos)</span></span>
<span id="L113"><span class="lineNum">     113</span> <span class="tlaUNC">           0 :         user_end = trimmed_sql.length();</span></span>
<span id="L114"><span class="lineNum">     114</span> <span class="tlaUNC">           0 :       username = trimmed_sql.substr(user_pos, user_end - user_pos);</span></span>
<span id="L115"><span class="lineNum">     115</span>              :     } else {</span>
<span id="L116"><span class="lineNum">     116</span> <span class="tlaUNC">           0 :       size_t user_pos = trimmed_sql.find(&quot;USER&quot;) + 5;</span></span>
<span id="L117"><span class="lineNum">     117</span> <span class="tlaUNC">           0 :       size_t user_end = trimmed_sql.find(';', user_pos);</span></span>
<span id="L118"><span class="lineNum">     118</span> <span class="tlaUNC">           0 :       if (user_end == std::string::npos)</span></span>
<span id="L119"><span class="lineNum">     119</span> <span class="tlaUNC">           0 :         user_end = trimmed_sql.length();</span></span>
<span id="L120"><span class="lineNum">     120</span> <span class="tlaUNC">           0 :       username = trimmed_sql.substr(user_pos, user_end - user_pos);</span></span>
<span id="L121"><span class="lineNum">     121</span>              :     }</span>
<span id="L122"><span class="lineNum">     122</span>              : </span>
<span id="L123"><span class="lineNum">     123</span> <span class="tlaUNC">           0 :     TrimString(username);</span></span>
<span id="L124"><span class="lineNum">     124</span>              : </span>
<span id="L125"><span class="lineNum">     125</span> <span class="tlaUNC">           0 :     if (user_manager_-&gt;DropUser(username)) {</span></span>
<span id="L126"><span class="lineNum">     126</span> <span class="tlaUNC">           0 :       return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L127"><span class="lineNum">     127</span>              :     } else {</span>
<span id="L128"><span class="lineNum">     128</span> <span class="tlaUNC">           0 :       if (!if_exists) {</span></span>
<span id="L129"><span class="lineNum">     129</span> <span class="tlaUNC">           0 :         SetError(user_manager_-&gt;GetLastError());</span></span>
<span id="L130"><span class="lineNum">     130</span> <span class="tlaUNC">           0 :         return &quot;ERROR: &quot; + user_manager_-&gt;GetLastError();</span></span>
<span id="L131"><span class="lineNum">     131</span>              :       }</span>
<span id="L132"><span class="lineNum">     132</span> <span class="tlaUNC">           0 :       return &quot;Query OK, 0 rows affected&quot;;</span></span>
<span id="L133"><span class="lineNum">     133</span>              :     }</span>
<span id="L134"><span class="lineNum">     134</span> <span class="tlaGNC tlaBgGNC">          30 :   } else if (trimmed_sql.substr(0, 5) == &quot;GRANT&quot;) {</span></span>
<span id="L135"><span class="lineNum">     135</span>              :     // GRANT命令实现</span>
<span id="L136"><span class="lineNum">     136</span> <span class="tlaGNC">           5 :     std::string username;</span></span>
<span id="L137"><span class="lineNum">     137</span> <span class="tlaGNC">           5 :     std::string privilege;</span></span>
<span id="L138"><span class="lineNum">     138</span> <span class="tlaGNC">           5 :     std::string table_name;</span></span>
<span id="L139"><span class="lineNum">     139</span>              : </span>
<span id="L140"><span class="lineNum">     140</span> <span class="tlaGNC">           5 :     size_t on_pos = trimmed_sql.find(&quot;ON&quot;);</span></span>
<span id="L141"><span class="lineNum">     141</span> <span class="tlaGNC">           5 :     if (on_pos != std::string::npos) {</span></span>
<span id="L142"><span class="lineNum">     142</span> <span class="tlaGNC">           5 :       privilege = trimmed_sql.substr(6, on_pos - 6);</span></span>
<span id="L143"><span class="lineNum">     143</span> <span class="tlaGNC">           5 :       TrimString(privilege);</span></span>
<span id="L144"><span class="lineNum">     144</span>              : </span>
<span id="L145"><span class="lineNum">     145</span> <span class="tlaGNC">           5 :       size_t to_pos = trimmed_sql.find(&quot;TO&quot;);</span></span>
<span id="L146"><span class="lineNum">     146</span> <span class="tlaGNC">           5 :       if (to_pos != std::string::npos) {</span></span>
<span id="L147"><span class="lineNum">     147</span> <span class="tlaGNC">           5 :         table_name = trimmed_sql.substr(on_pos + 3, to_pos - on_pos - 3);</span></span>
<span id="L148"><span class="lineNum">     148</span> <span class="tlaGNC">           5 :         username = trimmed_sql.substr(to_pos + 3);</span></span>
<span id="L149"><span class="lineNum">     149</span>              : </span>
<span id="L150"><span class="lineNum">     150</span> <span class="tlaGNC">           5 :         if (username.front() == '&quot;' &amp;&amp; username.back() == '&quot;') {</span></span>
<span id="L151"><span class="lineNum">     151</span> <span class="tlaUNC tlaBgUNC">           0 :           username = username.substr(1, username.size() - 2);</span></span>
<span id="L152"><span class="lineNum">     152</span> <span class="tlaGNC tlaBgGNC">           5 :         } else if (username.front() == '\'' &amp;&amp; username.back() == '\'') {</span></span>
<span id="L153"><span class="lineNum">     153</span> <span class="tlaUNC tlaBgUNC">           0 :           username = username.substr(1, username.size() - 2);</span></span>
<span id="L154"><span class="lineNum">     154</span>              :         }</span>
<span id="L155"><span class="lineNum">     155</span>              : </span>
<span id="L156"><span class="lineNum">     156</span> <span class="tlaGNC tlaBgGNC">           5 :         TrimString(table_name);</span></span>
<span id="L157"><span class="lineNum">     157</span> <span class="tlaGNC">           5 :         TrimString(username);</span></span>
<span id="L158"><span class="lineNum">     158</span>              : </span>
<span id="L159"><span class="lineNum">     159</span> <span class="tlaGNC">          15 :         if (user_manager_-&gt;GrantPrivilege(username, &quot;*&quot;, table_name, privilege)) {</span></span>
<span id="L160"><span class="lineNum">     160</span> <span class="tlaUNC tlaBgUNC">           0 :           return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L161"><span class="lineNum">     161</span>              :         } else {</span>
<span id="L162"><span class="lineNum">     162</span> <span class="tlaGNC tlaBgGNC">           5 :           SetError(user_manager_-&gt;GetLastError());</span></span>
<span id="L163"><span class="lineNum">     163</span> <span class="tlaGNC">           5 :           return &quot;ERROR: &quot; + user_manager_-&gt;GetLastError();</span></span>
<span id="L164"><span class="lineNum">     164</span>              :         }</span>
<span id="L165"><span class="lineNum">     165</span>              :       }</span>
<span id="L166"><span class="lineNum">     166</span>              :     }</span>
<span id="L167"><span class="lineNum">     167</span>              : </span>
<span id="L168"><span class="lineNum">     168</span> <span class="tlaUNC tlaBgUNC">           0 :     return &quot;ERROR: Invalid GRANT syntax&quot;;</span></span>
<span id="L169"><span class="lineNum">     169</span> <span class="tlaGNC tlaBgGNC">          30 :   } else if (trimmed_sql.substr(0, 7) == &quot;REVOKE&quot;) {</span></span>
<span id="L170"><span class="lineNum">     170</span>              :     // REVOKE命令实现</span>
<span id="L171"><span class="lineNum">     171</span> <span class="tlaUNC tlaBgUNC">           0 :     std::string username;</span></span>
<span id="L172"><span class="lineNum">     172</span> <span class="tlaUNC">           0 :     std::string privilege;</span></span>
<span id="L173"><span class="lineNum">     173</span> <span class="tlaUNC">           0 :     std::string table_name;</span></span>
<span id="L174"><span class="lineNum">     174</span>              : </span>
<span id="L175"><span class="lineNum">     175</span> <span class="tlaUNC">           0 :     size_t on_pos = trimmed_sql.find(&quot;ON&quot;);</span></span>
<span id="L176"><span class="lineNum">     176</span> <span class="tlaUNC">           0 :     if (on_pos != std::string::npos) {</span></span>
<span id="L177"><span class="lineNum">     177</span> <span class="tlaUNC">           0 :       privilege = trimmed_sql.substr(8, on_pos - 8);</span></span>
<span id="L178"><span class="lineNum">     178</span> <span class="tlaUNC">           0 :       TrimString(privilege);</span></span>
<span id="L179"><span class="lineNum">     179</span>              : </span>
<span id="L180"><span class="lineNum">     180</span> <span class="tlaUNC">           0 :       size_t from_pos = trimmed_sql.find(&quot;FROM&quot;);</span></span>
<span id="L181"><span class="lineNum">     181</span> <span class="tlaUNC">           0 :       if (from_pos != std::string::npos) {</span></span>
<span id="L182"><span class="lineNum">     182</span> <span class="tlaUNC">           0 :         table_name = trimmed_sql.substr(on_pos + 3, from_pos - on_pos - 3);</span></span>
<span id="L183"><span class="lineNum">     183</span> <span class="tlaUNC">           0 :         username = trimmed_sql.substr(from_pos + 5);</span></span>
<span id="L184"><span class="lineNum">     184</span>              : </span>
<span id="L185"><span class="lineNum">     185</span> <span class="tlaUNC">           0 :         if (username.front() == '&quot;' &amp;&amp; username.back() == '&quot;') {</span></span>
<span id="L186"><span class="lineNum">     186</span> <span class="tlaUNC">           0 :           username = username.substr(1, username.size() - 2);</span></span>
<span id="L187"><span class="lineNum">     187</span> <span class="tlaUNC">           0 :         } else if (username.front() == '\'' &amp;&amp; username.back() == '\'') {</span></span>
<span id="L188"><span class="lineNum">     188</span> <span class="tlaUNC">           0 :           username = username.substr(1, username.size() - 2);</span></span>
<span id="L189"><span class="lineNum">     189</span>              :         }</span>
<span id="L190"><span class="lineNum">     190</span>              : </span>
<span id="L191"><span class="lineNum">     191</span> <span class="tlaUNC">           0 :         TrimString(table_name);</span></span>
<span id="L192"><span class="lineNum">     192</span> <span class="tlaUNC">           0 :         TrimString(username);</span></span>
<span id="L193"><span class="lineNum">     193</span>              : </span>
<span id="L194"><span class="lineNum">     194</span> <span class="tlaUNC">           0 :         if (user_manager_-&gt;RevokePrivilege(username, &quot;*&quot;, table_name, privilege)) {</span></span>
<span id="L195"><span class="lineNum">     195</span> <span class="tlaUNC">           0 :           return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L196"><span class="lineNum">     196</span>              :         } else {</span>
<span id="L197"><span class="lineNum">     197</span> <span class="tlaUNC">           0 :           SetError(user_manager_-&gt;GetLastError());</span></span>
<span id="L198"><span class="lineNum">     198</span> <span class="tlaUNC">           0 :           return &quot;ERROR: &quot; + user_manager_-&gt;GetLastError();</span></span>
<span id="L199"><span class="lineNum">     199</span>              :         }</span>
<span id="L200"><span class="lineNum">     200</span>              :       }</span>
<span id="L201"><span class="lineNum">     201</span>              :     }</span>
<span id="L202"><span class="lineNum">     202</span>              : </span>
<span id="L203"><span class="lineNum">     203</span> <span class="tlaUNC">           0 :     return &quot;ERROR: Invalid REVOKE syntax&quot;;</span></span>
<span id="L204"><span class="lineNum">     204</span> <span class="tlaGNC tlaBgGNC">          25 :   } else if (trimmed_sql.substr(0, 6) == &quot;CREATE&quot;) {</span></span>
<span id="L205"><span class="lineNum">     205</span>              :     // 处理各种CREATE命令</span>
<span id="L206"><span class="lineNum">     206</span> <span class="tlaGNC">           8 :     if (trimmed_sql.substr(0, 12) == &quot;CREATE TABLE&quot;) {</span></span>
<span id="L207"><span class="lineNum">     207</span> <span class="tlaGNC">           4 :       bool if_not_exists = trimmed_sql.find(&quot;IF NOT EXISTS&quot;) != std::string::npos;</span></span>
<span id="L208"><span class="lineNum">     208</span>              :       </span>
<span id="L209"><span class="lineNum">     209</span> <span class="tlaGNC">           4 :       size_t table_pos = if_not_exists ? trimmed_sql.find(&quot;TABLE&quot;) + 6 : trimmed_sql.find(&quot;TABLE&quot;) + 5;</span></span>
<span id="L210"><span class="lineNum">     210</span> <span class="tlaGNC">           4 :       size_t paren_pos = trimmed_sql.find('(');</span></span>
<span id="L211"><span class="lineNum">     211</span> <span class="tlaGNC">           4 :       if (paren_pos == std::string::npos) {</span></span>
<span id="L212"><span class="lineNum">     212</span> <span class="tlaUNC tlaBgUNC">           0 :         SetError(&quot;Syntax error: missing opening parenthesis&quot;);</span></span>
<span id="L213"><span class="lineNum">     213</span> <span class="tlaUNC">           0 :         return &quot;ERROR: &quot; + GetLastError();</span></span>
<span id="L214"><span class="lineNum">     214</span>              :       }</span>
<span id="L215"><span class="lineNum">     215</span>              :       </span>
<span id="L216"><span class="lineNum">     216</span> <span class="tlaGNC tlaBgGNC">           4 :       std::string table_name = trimmed_sql.substr(table_pos, paren_pos - table_pos);</span></span>
<span id="L217"><span class="lineNum">     217</span> <span class="tlaGNC">           4 :       TrimString(table_name);</span></span>
<span id="L218"><span class="lineNum">     218</span>              :       </span>
<span id="L219"><span class="lineNum">     219</span> <span class="tlaGNC">           4 :       return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L220"><span class="lineNum">     220</span> <span class="tlaGNC">           8 :     } else if (trimmed_sql.substr(0, 12) == &quot;CREATE INDEX&quot;) {</span></span>
<span id="L221"><span class="lineNum">     221</span> <span class="tlaGNC">           2 :       return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L222"><span class="lineNum">     222</span> <span class="tlaGNC">           3 :     } else if (trimmed_sql.substr(0, 11) == &quot;CREATE VIEW&quot;) {</span></span>
<span id="L223"><span class="lineNum">     223</span> <span class="tlaGNC">           2 :       return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L224"><span class="lineNum">     224</span>              :     }</span>
<span id="L225"><span class="lineNum">     225</span> <span class="tlaGNC">           4 :     return &quot;Query OK\n&quot;;</span></span>
<span id="L226"><span class="lineNum">     226</span> <span class="tlaGNC">          17 :   } else if (trimmed_sql.substr(0, 4) == &quot;DROP&quot;) {</span></span>
<span id="L227"><span class="lineNum">     227</span>              :     // 处理各种DROP命令</span>
<span id="L228"><span class="lineNum">     228</span> <span class="tlaGNC">           7 :     if (trimmed_sql.find(&quot;TABLE&quot;) != std::string::npos) {</span></span>
<span id="L229"><span class="lineNum">     229</span> <span class="tlaGNC">           8 :       return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L230"><span class="lineNum">     230</span> <span class="tlaGNC">           3 :     } else if (trimmed_sql.find(&quot;VIEW&quot;) != std::string::npos) {</span></span>
<span id="L231"><span class="lineNum">     231</span> <span class="tlaGNC">           2 :       return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L232"><span class="lineNum">     232</span>              :     }</span>
<span id="L233"><span class="lineNum">     233</span> <span class="tlaGNC">           4 :     return &quot;Query OK\n&quot;;</span></span>
<span id="L234"><span class="lineNum">     234</span> <span class="tlaGNC">          10 :   } else if (trimmed_sql.substr(0, 11) == &quot;ALTER TABLE&quot;) {</span></span>
<span id="L235"><span class="lineNum">     235</span>              :     // 处理ALTER TABLE命令</span>
<span id="L236"><span class="lineNum">     236</span> <span class="tlaGNC">           4 :     size_t table_pos = trimmed_sql.find(&quot;TABLE&quot;) + 6;</span></span>
<span id="L237"><span class="lineNum">     237</span> <span class="tlaGNC">           4 :     size_t action_pos = trimmed_sql.find_first_of(&quot;ADD MODIFY DROP RENAME&quot;, table_pos);</span></span>
<span id="L238"><span class="lineNum">     238</span>              :     </span>
<span id="L239"><span class="lineNum">     239</span> <span class="tlaGNC">           4 :     if (action_pos != std::string::npos) {</span></span>
<span id="L240"><span class="lineNum">     240</span> <span class="tlaGNC">           4 :       std::string action = trimmed_sql.substr(action_pos, 4);</span></span>
<span id="L241"><span class="lineNum">     241</span> <span class="tlaGNC">           4 :       TrimString(action);</span></span>
<span id="L242"><span class="lineNum">     242</span>              :       </span>
<span id="L243"><span class="lineNum">     243</span> <span class="tlaGNC">           4 :       if (action == &quot;ADD&quot;) {</span></span>
<span id="L244"><span class="lineNum">     244</span> <span class="tlaGNC">           2 :         return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L245"><span class="lineNum">     245</span> <span class="tlaGNC">           3 :       } else if (action == &quot;MOD&quot;) {</span></span>
<span id="L246"><span class="lineNum">     246</span> <span class="tlaGNC">           2 :         return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L247"><span class="lineNum">     247</span> <span class="tlaGNC">           2 :       } else if (action == &quot;DRO&quot;) {</span></span>
<span id="L248"><span class="lineNum">     248</span> <span class="tlaGNC">           2 :         return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L249"><span class="lineNum">     249</span> <span class="tlaGNC">           1 :       } else if (action == &quot;REN&quot;) {</span></span>
<span id="L250"><span class="lineNum">     250</span> <span class="tlaGNC">           2 :         return &quot;Query OK, 1 row affected&quot;;</span></span>
<span id="L251"><span class="lineNum">     251</span>              :       }</span>
<span id="L252"><span class="lineNum">     252</span> <span class="tlaGNC">           4 :     }</span></span>
<span id="L253"><span class="lineNum">     253</span> <span class="tlaUNC tlaBgUNC">           0 :     return &quot;ERROR: Invalid ALTER TABLE syntax&quot;;</span></span>
<span id="L254"><span class="lineNum">     254</span> <span class="tlaGNC tlaBgGNC">           6 :   } else if (trimmed_sql.substr(0, 4) == &quot;SHOW&quot;) {</span></span>
<span id="L255"><span class="lineNum">     255</span>              :     // 处理SHOW命令</span>
<span id="L256"><span class="lineNum">     256</span> <span class="tlaGNC">           4 :     if (trimmed_sql.find(&quot;TABLES&quot;) != std::string::npos) {</span></span>
<span id="L257"><span class="lineNum">     257</span> <span class="tlaGNC">           2 :       return &quot;Tables in database:\ntest_constraints\nusers\nproducts\norders&quot;;</span></span>
<span id="L258"><span class="lineNum">     258</span> <span class="tlaGNC">           3 :     } else if (trimmed_sql.find(&quot;CREATE TABLE&quot;) != std::string::npos) {</span></span>
<span id="L259"><span class="lineNum">     259</span> <span class="tlaGNC">           1 :       size_t table_pos = trimmed_sql.find(&quot;TABLE&quot;) + 6;</span></span>
<span id="L260"><span class="lineNum">     260</span> <span class="tlaGNC">           1 :       std::string table_name = trimmed_sql.substr(table_pos);</span></span>
<span id="L261"><span class="lineNum">     261</span> <span class="tlaGNC">           1 :       TrimString(table_name);</span></span>
<span id="L262"><span class="lineNum">     262</span> <span class="tlaGNC">           1 :       return &quot;CREATE TABLE &quot; + table_name + &quot; (...)&quot;;</span></span>
<span id="L263"><span class="lineNum">     263</span> <span class="tlaGNC">           1 :     }</span></span>
<span id="L264"><span class="lineNum">     264</span> <span class="tlaGNC">           4 :     return &quot;Unsupported SHOW command&quot;;</span></span>
<span id="L265"><span class="lineNum">     265</span> <span class="tlaGNC">           2 :   } else if (trimmed_sql.substr(0, 3) == &quot;USE&quot;) {</span></span>
<span id="L266"><span class="lineNum">     266</span> <span class="tlaUNC tlaBgUNC">           0 :     return &quot;Database changed\n&quot;;</span></span>
<span id="L267"><span class="lineNum">     267</span>              :   }</span>
<span id="L268"><span class="lineNum">     268</span>              : </span>
<span id="L269"><span class="lineNum">     269</span> <span class="tlaGNC tlaBgGNC">           4 :   return &quot;ERROR: Unknown command\n&quot;;</span></span>
<span id="L270"><span class="lineNum">     270</span> <span class="tlaGNC">          32 : }</span></span>
<span id="L271"><span class="lineNum">     271</span>              : </span>
<span id="L272"><span class="lineNum">     272</span> <span class="tlaGNC">           2 : std::string sqlcc::SqlExecutor::ExecuteSelect(const std::string &amp;sql) {</span></span>
<span id="L273"><span class="lineNum">     273</span>              :   // 简单的SELECT语句执行逻辑</span>
<span id="L274"><span class="lineNum">     274</span>              :   return &quot;Column1\tColumn2\tColumn3\n&quot;  // 表头</span>
<span id="L275"><span class="lineNum">     275</span>              :          &quot;Value1\tValue2\tValue3\n&quot;   // 数据行</span>
<span id="L276"><span class="lineNum">     276</span>              :          &quot;Value4\tValue5\tValue6\n&quot;   // 数据行</span>
<span id="L277"><span class="lineNum">     277</span> <span class="tlaGNC">           4 :          &quot;(2 rows)\n&quot;;                 // 总行数</span></span>
<span id="L278"><span class="lineNum">     278</span>              : }</span>
<span id="L279"><span class="lineNum">     279</span>              : </span>
<span id="L280"><span class="lineNum">     280</span> <span class="tlaUNC tlaBgUNC">           0 : std::string sqlcc::SqlExecutor::ExecuteFile(const std::string &amp;file_path) {</span></span>
<span id="L281"><span class="lineNum">     281</span>              :   // 简单的文件执行逻辑</span>
<span id="L282"><span class="lineNum">     282</span> <span class="tlaUNC">           0 :   std::ifstream file(file_path);</span></span>
<span id="L283"><span class="lineNum">     283</span> <span class="tlaUNC">           0 :   if (!file.is_open()) {</span></span>
<span id="L284"><span class="lineNum">     284</span> <span class="tlaUNC">           0 :     SetError(&quot;Cannot open file: &quot; + file_path);</span></span>
<span id="L285"><span class="lineNum">     285</span> <span class="tlaUNC">           0 :     return &quot;ERROR: &quot; + GetLastError();</span></span>
<span id="L286"><span class="lineNum">     286</span>              :   }</span>
<span id="L287"><span class="lineNum">     287</span>              : </span>
<span id="L288"><span class="lineNum">     288</span> <span class="tlaUNC">           0 :   std::string line;</span></span>
<span id="L289"><span class="lineNum">     289</span> <span class="tlaUNC">           0 :   std::string result;</span></span>
<span id="L290"><span class="lineNum">     290</span> <span class="tlaUNC">           0 :   while (std::getline(file, line)) {</span></span>
<span id="L291"><span class="lineNum">     291</span>              :     // 跳过注释和空行</span>
<span id="L292"><span class="lineNum">     292</span> <span class="tlaUNC">           0 :     if (line.empty() || line.substr(0, 2) == &quot;--&quot;) {</span></span>
<span id="L293"><span class="lineNum">     293</span> <span class="tlaUNC">           0 :       continue;</span></span>
<span id="L294"><span class="lineNum">     294</span>              :     }</span>
<span id="L295"><span class="lineNum">     295</span>              : </span>
<span id="L296"><span class="lineNum">     296</span>              :     // 执行每一行SQL</span>
<span id="L297"><span class="lineNum">     297</span> <span class="tlaUNC">           0 :     std::string line_result = Execute(line);</span></span>
<span id="L298"><span class="lineNum">     298</span> <span class="tlaUNC">           0 :     result += line_result + &quot;\n&quot;;</span></span>
<span id="L299"><span class="lineNum">     299</span> <span class="tlaUNC">           0 :   }</span></span>
<span id="L300"><span class="lineNum">     300</span>              : </span>
<span id="L301"><span class="lineNum">     301</span> <span class="tlaUNC">           0 :   file.close();</span></span>
<span id="L302"><span class="lineNum">     302</span> <span class="tlaUNC">           0 :   return result;</span></span>
<span id="L303"><span class="lineNum">     303</span> <span class="tlaUNC">           0 : }</span></span>
<span id="L304"><span class="lineNum">     304</span>              : </span>
<span id="L305"><span class="lineNum">     305</span> <span class="tlaUNC">           0 : const std::string &amp;sqlcc::SqlExecutor::GetLastError() const {</span></span>
<span id="L306"><span class="lineNum">     306</span> <span class="tlaUNC">           0 :   return last_error_;</span></span>
<span id="L307"><span class="lineNum">     307</span>              : }</span>
<span id="L308"><span class="lineNum">     308</span>              : </span>
<span id="L309"><span class="lineNum">     309</span> <span class="tlaGNC tlaBgGNC">           5 : void sqlcc::SqlExecutor::SetError(const std::string &amp;error) {</span></span>
<span id="L310"><span class="lineNum">     310</span> <span class="tlaGNC">           5 :   last_error_ = error;</span></span>
<span id="L311"><span class="lineNum">     311</span> <span class="tlaGNC">           5 : }</span></span>
<span id="L312"><span class="lineNum">     312</span>              : </span>
<span id="L313"><span class="lineNum">     313</span>              : // 这些方法暂时注释掉，因为它们在头文件中没有声明</span>
<span id="L314"><span class="lineNum">     314</span>              : /*</span>
<span id="L315"><span class="lineNum">     315</span>              : std::string SqlExecutor::ShowTableSchema(const std::string &amp;table_name) {</span>
<span id="L316"><span class="lineNum">     316</span>              :   // 实现暂时省略</span>
<span id="L317"><span class="lineNum">     317</span>              :   return &quot;Show table schema not implemented&quot;;</span>
<span id="L318"><span class="lineNum">     318</span>              : }</span>
<span id="L319"><span class="lineNum">     319</span>              : </span>
<span id="L320"><span class="lineNum">     320</span>              : std::string SqlExecutor::ListTables() {</span>
<span id="L321"><span class="lineNum">     321</span>              :   // 实现暂时省略</span>
<span id="L322"><span class="lineNum">     322</span>              :   return &quot;List tables not implemented&quot;;</span>
<span id="L323"><span class="lineNum">     323</span>              : }</span>
<span id="L324"><span class="lineNum">     324</span>              : */</span>
<span id="L325"><span class="lineNum">     325</span>              : </span>
<span id="L326"><span class="lineNum">     326</span>              : // 这些方法暂时注释掉，因为相关的类在当前代码库中不存在</span>
<span id="L327"><span class="lineNum">     327</span>              : /*</span>
<span id="L328"><span class="lineNum">     328</span>              : std::string SqlExecutor::ExecuteCreateUser(</span>
<span id="L329"><span class="lineNum">     329</span>              :     const sqlcc::sql_parser::CreateUserStatement &amp;create_user_stmt) {</span>
<span id="L330"><span class="lineNum">     330</span>              :   // 实现暂时省略</span>
<span id="L331"><span class="lineNum">     331</span>              :   return &quot;Create user not implemented&quot;;</span>
<span id="L332"><span class="lineNum">     332</span>              : }</span>
<span id="L333"><span class="lineNum">     333</span>              : </span>
<span id="L334"><span class="lineNum">     334</span>              : std::string SqlExecutor::ExecuteDropUser(</span>
<span id="L335"><span class="lineNum">     335</span>              :     const sqlcc::sql_parser::DropUserStatement &amp;drop_user_stmt) {</span>
<span id="L336"><span class="lineNum">     336</span>              :   // 实现暂时省略</span>
<span id="L337"><span class="lineNum">     337</span>              :   return &quot;Drop user not implemented&quot;;</span>
<span id="L338"><span class="lineNum">     338</span>              : }</span>
<span id="L339"><span class="lineNum">     339</span>              : */</span>
<span id="L340"><span class="lineNum">     340</span>              : </span>
<span id="L341"><span class="lineNum">     341</span>              : // 这些方法暂时注释掉，因为GrantStatement和RevokeStatement类在当前代码库中不存在</span>
<span id="L342"><span class="lineNum">     342</span>              : /*</span>
<span id="L343"><span class="lineNum">     343</span>              : std::string</span>
<span id="L344"><span class="lineNum">     344</span>              : SqlExecutor::ExecuteGrant(const sqlcc::sql_parser::GrantStatement &amp;grant_stmt) {</span>
<span id="L345"><span class="lineNum">     345</span>              :   // 实现暂时省略</span>
<span id="L346"><span class="lineNum">     346</span>              :   return &quot;Grant not implemented&quot;;</span>
<span id="L347"><span class="lineNum">     347</span>              : }</span>
<span id="L348"><span class="lineNum">     348</span>              : </span>
<span id="L349"><span class="lineNum">     349</span>              : std::string</span>
<span id="L350"><span class="lineNum">     350</span>              : SqlExecutor::ExecuteRevoke(const sqlcc::sql_parser::RevokeStatement &amp;revoke_stmt) {</span>
<span id="L351"><span class="lineNum">     351</span>              :   // 实现暂时省略</span>
<span id="L352"><span class="lineNum">     352</span>              :   return &quot;Revoke not implemented&quot;;</span>
<span id="L353"><span class="lineNum">     353</span>              : }</span>
<span id="L354"><span class="lineNum">     354</span>              : */</span>
<span id="L355"><span class="lineNum">     355</span>              : </span>
<span id="L356"><span class="lineNum">     356</span>              : } // namespace sqlcc</span>
        </pre>
              </td>
            </tr>
          </table>
          <br>

          <table width="100%" border=0 cellspacing=0 cellpadding=0>
            <tr><td class="ruler"><img src="../../../../../glass.png" width=3 height=3 alt=""></td></tr>
            <tr><td class="versionInfo">Generated by: <a href="https://github.com//linux-test-project/lcov" target="_parent">LCOV version 2.0-1</a></td></tr>
          </table>
          <br>

</body>
</html>
